package com.bins.redis.pubsub;

import lombok.NonNull;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

@Slf4j
public class RedisMessageListenner implements MessageListener {

	private final Logger logger = LoggerFactory.getLogger(this.getClass());

	@Override
	public void onMessage(@NonNull Message message, byte[] pattern) {

		logger.error("message received: {}", message);
	}
}